package com.lzy.cloud.mq.config;

import org.springframework.amqp.core.*;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashMap;
import java.util.Map;

/**
 * Created with IntelliJ IDEA.
 * Description: lzy-cloud-service
 *
 * @author: ellengou
 * @date: 2018-07-18 星期三
 * @time: 11:59
 */

@Configuration
public class ConfigMq {

    /******************************  测试实时发送队列配置开始  ******************************/
    /**
     * 队列定义
     * @return
     */
    @Bean("testQueue")
    public Queue testQueue() {
        //定义一个routingKey为test.payment的消息队列
        return new Queue("test.payment");
    }

    /**
     * 交换机定义（topic）
     */
    @Bean
    public TopicExchange testExchange() {
        return new TopicExchange("testExchange");
    }


    /**
     * 绑定交换机
     */
    @Bean
    public Binding bindingTestExchange(Queue testQueue, TopicExchange testExchange) {
        return BindingBuilder.bind(testQueue).to(testExchange).with("test.payment.#");
    }
    /******************************  测试实时发送队列配置结束  ******************************/

    /******************************  第三方支付回调业务处理实时发送队列配置开始  ******************************/
    /**
     * 消息队列
     */
    public static final String PAYMENT_QUEUE = "payment.queue";
    /**
     * 交换机
     */
    public static final String PAYMENT_EXCHANGE = "paymentExchange";
    /**
     * routing key 名称
     */
    public static final String PAYMENT_ROUTING_KEY = "payment.routing.key";

    /**
     * 队列定义
     * @return
     */
    @Bean
    public Queue paymentQueue() {
        //定义一个routingKey为test.payment的消息队列
        return new Queue(PAYMENT_QUEUE);
    }

    /**
     * 交换机定义（topic）
     */
    @Bean
    public TopicExchange paymentExchange() {
        return new TopicExchange(PAYMENT_EXCHANGE);
    }


    /**
     * 绑定交换机
     */
    @Bean
    public Binding bindingPaymentExchange(Queue testQueue, TopicExchange testExchange) {
        return BindingBuilder.bind(paymentQueue()).to(paymentExchange()).with(PAYMENT_ROUTING_KEY+".#");
    }
    /******************************  第三方支付回调业务处理实时发送队列配置开始  ******************************/

    /******************************  订单延迟队列配置开始  ******************************/
    /**
     * 延迟队列 TTL 名称
     */
    private static final String REGISTER_DELAY_QUEUE = "order.cancel.delay.queue";
    /**
     * DLX，dead letter发送到的 exchange
     */
    public static final String REGISTER_DELAY_EXCHANGE = "orderCancelDelayExchange";
    /**
     * routing key 名称
     * 此处的 routingKey 很重要要,具体消息发送在该 routingKey 的
     */
    public static final String DELAY_ROUTING_KEY = "order.cancel.delay.routing.key";
    /**
     * 接收者消息队列
     */
    public static final String REGISTER_QUEUE_NAME = "order.cancel.queue";
    /**
     * 接收者交换机
     */
    public static final String REGISTER_EXCHANGE_NAME = "orderCancelExchange";
    /**
     * 接收者 routing key 名称
     */
    public static final String ROUTING_KEY = "order.cancel.routing.key";

    @Bean
    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
        connectionFactory.setPublisherConfirms(true);
        connectionFactory.setPublisherReturns(true);
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMandatory(true);
        return rabbitTemplate;
    }

    /**
     * 延迟队列配置
     * <p>
     * 1、params.put("x-message-ttl", 5 * 1000);
     * 第一种方式是直接设置 Queue 延迟时间 但如果直接给队列设置过期时间,这种做法不是很灵活,（当然二者是兼容的,默认是时间小的优先）
     * 2、rabbitTemplate.convertAndSend(book, message -> {
     * message.getMessageProperties().setExpiration(2 * 1000 + "");
     * return message;
     * });
     * 第二种就是每次发送消息动态设置延迟时间,这样我们可以灵活控制
     **/
    @Bean
    public Queue delayProcessQueue() {
        Map<String, Object> params = new HashMap<>();
        // x-dead-letter-exchange 声明了队列里的死信转发到的DLX名称，
        params.put("x-dead-letter-exchange", REGISTER_EXCHANGE_NAME);
        // x-dead-letter-routing-key 声明了这些死信在转发时携带的 routing-key 名称。
        params.put("x-dead-letter-routing-key", ROUTING_KEY);
        return new Queue(REGISTER_DELAY_QUEUE, true, false, false, params);
    }

    /**
     * 需要将一个队列绑定到交换机上，要求该消息与一个特定的路由键完全匹配。
     * 这是一个完整的匹配。如果一个队列绑定到该交换机上要求路由键 “dog”，则只有被标记为“dog”的消息才被转发，不会转发dog.puppy，也不会转发dog.guard，只会转发dog。
     * 它不像 TopicExchange 那样可以使用通配符适配多个
     *
     * @return DirectExchange
     */
    @Bean
    public DirectExchange delayExchange() {
        return new DirectExchange(REGISTER_DELAY_EXCHANGE);
    }

    @Bean
    public Binding dlxBinding() {
        return BindingBuilder.bind(delayProcessQueue()).to(delayExchange()).with(DELAY_ROUTING_KEY);
    }

    @Bean
    public Queue registerBookQueue() {
        return new Queue(REGISTER_QUEUE_NAME, true);
    }

    /**
     * 将路由键和某模式进行匹配。此时队列需要绑定要一个模式上。
     * 符号“#”匹配一个或多个词，符号“*”匹配不多不少一个词。因此“audit.#”能够匹配到“audit.irs.corporate”，但是“audit.*” 只会匹配到“audit.irs”。
     **/
    @Bean
    public TopicExchange registerBookTopicExchange() {
        return new TopicExchange(REGISTER_EXCHANGE_NAME);
    }

    @Bean
    public Binding registerBookBinding() {
        // 如果要让延迟队列之间有关联,这里的 routingKey 和 绑定的交换机很关键
        return BindingBuilder.bind(registerBookQueue()).to(registerBookTopicExchange()).with(ROUTING_KEY);
    }
    /******************************  订单延迟队列配置结束  ******************************/

    /******************************   退订退款实时发送队列开始  ******************************/
    /**
     * 消息队列
     */
    public static final String UNSUBSCRIBE_QUEUE = "unsubscribe.queue";
    /**
     * 交换机
     */
    public static final String UNSUBSCRIBE_EXCHANGE = "unsubscribeExchange";
    /**
     * routing key 名称
     */
    public static final String UNSUBSCRIBE_ROUTING_KEY = "unsubscribe.routing.key";

    /**
     * 队列定义
     * @return
     */
    @Bean
    public Queue unsubscribeQueue() {
        //定义一个routingKey为test.payment的消息队列
        return new Queue(UNSUBSCRIBE_QUEUE);
    }

    /**
     * 交换机定义（topic）
     */
    @Bean
    public TopicExchange unsubscribeExchange() {
        return new TopicExchange(UNSUBSCRIBE_EXCHANGE);
    }


    /**
     * 绑定交换机
     */
    @Bean
    public Binding bindingUnsubscribeExchange(Queue testQueue, TopicExchange testExchange) {
        return BindingBuilder.bind(unsubscribeQueue()).to(unsubscribeExchange()).with(UNSUBSCRIBE_ROUTING_KEY+".#");
    }

    /******************************   退订退款实时发送队列结束  ******************************/
}
